return eventStream(request.signal, send => {
  emitter.addEventListener("event", handler)
  return () => emitter.removeEventListener("event", handler);

  function handler(event: Event) {
    send({ data: event });
  }
}

return eventStream(request.signal, (send) =>
  emitter.subscribe((event) => {
    send({ data: event });
  }),
);

return eventStream(request.signal, (send) => {
  run()
  return () => {}; // empty cleanup

  async function run() {
    for await (const chunk of stream) {
      if (request.signal.aborted) return;
      send({ data: chunk });
    }
  }
});

let stream = new Stream(); // get your stream here

return eventStream(request.signal, {
  // This function will be called when the connection is closed, it can be an
  // async function or a sync function, depends on your needs.
  cleanup() {
    return stream.close()
  },

  // This function will be called when the connection is open, here you can send
  // data to the browser or close the connection
  async handle(send, close) {
    // iterate the async stream of data
    for await (const chunk of stream) {
      // stop the iteration if the connection is closed
      if (request.signal.aborted) return;
      send({ data: chunk }); // send each chunk
    }

    return close(); // close the connection when the stream ends
  }
});

import { client } from "~/services/openai.server";

export async function loader({ request }: LoaderFunctionArgs) {
  let stream = await client.chat.completions.create({
    model: "gpt-4",
    messages: [{ role: "user", content: "Say this is a test" }],
    stream: true,
  });

  return eventStream(controller.signal, {
    cleanup() {
      stream.controller.abort();
    },
    async handle(send, close) {
      for await (const chunk of stream) {
        send({ data: chunk.choices[0]?.delta?.content || "" });
      }

      return close();
    },
  });
}